package com.ydl.learning.flink.demo.transformations

import com.ydl.learning.flink.demo.Utils

/**
 *
 *
 * @author ydl
 * @since 2020/9/22
 */
object FilterDemo extends Utils {
  def main(args: Array[String]): Unit = {
    val stream = getSocketTextStream(9999)
    stream._2.filter(_.length > 2).print()
    stream._1.execute("start")
  }
}
